/*
授权声明：
本源码系《Java多线程编程实战指南（设计模式篇）》一书（ISBN：978-1-7-121-27006-2，以下称之为“原书”）的配套源码，
欲了解本代码的更多细节，请参考原书。
本代码仅为原书的配套说明之用，并不附带任何承诺（如质量保证和收益）。
以任何形式将本代码之部分或者全部用于营利性用途需经版权人书面同意。
将本代码之部分或者全部用于非营利性用途需要在代码中保留本声明。
任何对本代码的修改需在代码中以注释的形式注明修改人、修改时间以及修改内容。
本代码可以从下URL下载：
https://github.com/Viscent/javamtp
http://www.broadview.com.cn/27006
*/

package io.github.viscent.mtpattern.ch7.pc;

import java.util.concurrent.BlockingQueue;

/**
 * 基于阻塞队列的通道实现。
 * 
 * @author Viscent Huang
 *
 * @param <P> “产品”类型
 */
public class BlockingQueueChannel<P> implements Channel<P> {
	private final BlockingQueue<P> queue;

	public BlockingQueueChannel(BlockingQueue<P> queue) {
		this.queue = queue;
	}

	@Override
	public P take() throws InterruptedException {

		return queue.take();
	}

	@Override
	public void put(P product) throws InterruptedException {
		queue.put(product);

	}

}
